package com.xmhmyh.generalframework.framework.redisQueue.consumers;

import com.xmhmyh.generalframework.framework.redisQueue.RedisQueueMessage;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class MyConsumer implements RedisQueueConsumer {
    @Override
    public String getQueueName() {
        return "myConsumer";
    }

    @Override
    public void getMessage(RedisQueueMessage redisQueueMessage) {
        log.info("接收到了消息："+redisQueueMessage.toString());
    }

    @Override
    public void error(String error) {

    }

}
